59507381c8c725e28b2978641e638b7c7931f4e9,src/com/comcast/cns/util/CNSWorkerStatWrapper.java,CNSWorkerStatWrapper,getCassandraWorkerStats,#,31
Before Change
private static Logger logger = Logger.getLogger(CNSWorkerStatWrapper.class);
public static List<CNSWorkerStats> getCassandraWorkerStats(){
CassandraPersistence cassandraHandler = new CassandraPersistence(CMBProperties.getInstance().getCNSKeyspace());
List<Row<String, String, String>> rows = cassandraHandler.readNextNNonEmptyRows("CNSWorkers", null, 1000, 10, new StringSerializer(), new StringSerializer(), new StringSerializer(), CMBProperties.getInstance().getReadConsistencyLevel());
List<CNSWorkerStats> statsList = new ArrayList<CNSWorkerStats>();
After Change
private static Logger logger = Logger.getLogger(CNSWorkerStatWrapper.class);
public static List<CNSWorkerStats> getCassandraWorkerStats(){
AbstractCassandraPersistence cassandraHandler = CassandraPersistenceFactory.getInstance(CMBProperties.getInstance().getCNSKeyspace());
List<Row<String, String, String>> rows = cassandraHandler.readNextNNonEmptyRows("CNSWorkers", null, 1000, 10, new StringSerializer(), new StringSerializer(), new StringSerializer(), CMBProperties.getInstance().getReadConsistencyLevel());
List<CNSWorkerStats> statsList = new ArrayList<CNSWorkerStats>();